package com.af.monitorModule.generator;

import com.af.monitorModule.controller.websocket.InformationSocket;
import com.alibaba.fastjson.JSONObject;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;

/**
 * @author lyz
 * 此类用作处理钉钉推送消息到大屏的信息过滤
 * 凡是符合推送条件的 便放至信息队列中
 */
@Component
@Async
public class QualityInspector {

    private static final Logger logger = LoggerFactory.getLogger(QualityInspector.class);

    public void inspect(JSONObject sendObject){
        logger.info("收到推送信息，进行大屏推送" + sendObject.toJSONString());
        InformationSocket.MSG_QUEUE.add(sendObject.toJSONString());
    }
}
